package cn.cheneyjoo.kafka;

public interface KafkaMapper {
    /**
     * 生产消息
     * @param msg
     */
    void ProducerMessage(Object msg);
}
